#pragma once
#include <grpcpp/grpcpp.h>
#include "DataExchange.grpc.pb.h"
#include "DataExchange.pb.h"
#include <Qthread>
#include "call_data.h"
#include<mutex>
#include<thread>
#include <future>
class ResponseListener  {

private:
	std::shared_ptr<grpc::CompletionQueue> cq_;
	void run();
public:
	ResponseListener(std::shared_ptr<grpc::CompletionQueue> cq);
	~ResponseListener();
	
	void start();
	void stop();
	std::future<void> thread;


};